#异步任务装饰器
from celery import shared_task
#定义咱们异步任务
import time

from utils.sendsms import send_message


#name属性是传递的任务名字 不指定就是函数名
@shared_task(name="send_email")
def send_email(name):
    print("向"+name+"发送邮件")
    time.sleep(5)
    print("邮件发送成功")
    return "okk"


@shared_task(name="send_sms")
def sendmes(name):
    print("向"+name+"sayhello")


@shared_task()
def send(phone,code):
    res = send_message(phone,code)
    return res


from user import models


@shared_task()
def say():
    # models.User.objects.filter(addtime__lt="2022-01-01").update(isdel=True)
    #根据业务清理数据  发送生日祝福  统计数据等等
    print("定时任务执行了 hello")

